package com.dtruth.kafka.producer;

import kafka.producer.Partitioner;

public class KafkaPartition implements Partitioner {

	@Override
	public int partition(Object arg0, int arg1) {
		return 0;
	}
}
